package mqtt

import (
	"context"
	"fmt"

	"zerorpc/app/worker/internal/svc"
)

type Consumer struct {
	Ctx context.Context
	*svc.ServiceContext
}

func NewMqttConsumer(ctx context.Context, svcCtx *svc.ServiceContext) *Consumer {
	return &Consumer{
		Ctx:            ctx,
		ServiceContext: svcCtx,
	}
}

func (c *Consumer) Start() {
	fmt.Println("MQTT Consumer Start")
}

func (c *Consumer) Stop() {
	fmt.Println("MQTT Consumer Stop")
}
